//package com.cloud2022.order.canal;
//
//import com.alibaba.otter.canal.client.CanalConnector;
//import com.alibaba.otter.canal.client.CanalConnectors;
//import org.springframework.beans.factory.InitializingBean;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.stereotype.Component;
//
//import java.net.InetSocketAddress;
//
///**
// * @author: create by God of SJF
// * @version: v1.0
// * @description: com.cloud2022.order.canal
// * @date:2022/2/11
// */
//
//@Component
//public class CanalConnectorBean implements InitializingBean {
//
//    CanalConnector connector;
//
//    @Value("${canal.host}")
//    String canalHost;
//    @Value("${canal.port}")
//    Integer canalPort;
//    @Value("${canal.destination}")
//    String destination;
//
//    @Override
//    public void afterPropertiesSet() throws Exception {
//        connector = CanalConnectors.newSingleConnector(new InetSocketAddress(canalHost,
//                canalPort), destination, "", "");
//    }
//}
